//package org.example.gradle.jp.zk;
//
//import org.I0Itec.zkclient.ZkClient;
//
//public class ZkClientExample {
//
//    public static void main(String[] args) {
//        // 1. 定义连接参数
//        String zkServers = "192.168.254.200:2181"; // ZooKeeper服务器地址
//        int sessionTimeout = 30000; // 会话超时30秒
//        int connectionTimeout = 50000; // 连接超时5秒
//
//        // 2. 创建ZkClient实例（即建立连接）
//        ZkClient zkClient = new ZkClient(zkServers, sessionTimeout, connectionTimeout);
//
//        try {
//            System.out.println("成功连接到ZooKeeper服务器！");
//
//
//            // 关键步骤：设置自定义的字符串序列化器
//            zkClient.setZkSerializer(new StringSerializer());
//
//
//            // 3. 在这里进行你的ZooKeeper操作，例如：
//            // - 检查节点是否存在
//            if (!zkClient.exists("/myApp")) {
//                // 创建持久节点，初始数据为"Hello ZK"
//                zkClient.createPersistent("/myApp", "Hello ZK");
//                System.out.println("节点 /myApp 创建成功。");
//            }
//
//            // - 读取节点数据
//            String data = zkClient.readData("/myApp");
//            System.out.println("节点 /myApp 的数据是: " + data);
//
//        } catch (Exception e) {
//            e.printStackTrace();
//        } finally {
//            // 4. 最后务必关闭连接，释放资源
//            if (zkClient != null) {
//                zkClient.close();
//                System.out.println("连接已关闭。");
//            }
//        }
//    }
//}